package com.hrz.datasync.kafka.producer;

import com.hrz.datasync.pojo.secondary.BbqAdZone;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

/**
 * @作  者: 侯建军
 * @日  期: 2018/11/05 10:19:04
 * @描  述: AdZone生产数据
 */
@Component
public class BbqAdZoneProducer {
    @Autowired
    private KafkaSender<BbqAdZone> kafkaSender;
    public void adZoneSend(BbqAdZone bbqAdZone){
//        发送TpAdZone主题消息
        kafkaSender.send(bbqAdZone,"bbqzdzone");
    }
}
